package o;

import java.util.concurrent.Executor;

public final class fjv<TResult> implements fjs<TResult> {
    private fjq<TResult> ˊ;
    Executor ˋ;
    private final Object ˏ = new Object();

    fjv(Executor executor, fjq<TResult> o_fjq_TResult) {
        this.ˊ = o_fjq_TResult;
        this.ˋ = executor;
    }

    public final void ॱ(final fjo<TResult> o_fjo_TResult) {
        this.ˋ.execute(new Runnable(this) {
            final /* synthetic */ fjv ˏ;

            public final void run() {
                synchronized (this.ˏ.ˏ) {
                    if (this.ˏ.ˊ != null) {
                        this.ˏ.ˊ.onComplete(o_fjo_TResult);
                    }
                }
            }
        });
    }
}
